d9ecbea9ea8f9ea8d01af7b4b0f0014bbc8e0a02,app/src/main/java/chat/rocket/android/service/RealmBasedConnectivityManager.java,RealmBasedConnectivityManager,waitForDisconnected,#String#,193
Before Change
.filter(serverConnectivity -> (hostname.equals(serverConnectivity.hostname)
&& serverConnectivity.state == ServerConnectivity.STATE_DISCONNECTED))
.first()
.map(serverConnectivity -> true)
.toSingle();
}
private Single<Boolean> connectToServer(String hostname) {
After Change
private Single<Boolean> waitForDisconnected(String hostname) {
return connectivitySubject
.filter(serverConnectivity -> hostname.equals(serverConnectivity.hostname))
.map(serverConnectivity -> serverConnectivity.state)
.filter(state -> state == ServerConnectivity.STATE_DISCONNECTED)
.first()
.toSingle()
.map(state -> true);
}
@DebugLog